socketio/dev.adven.sockit.api/[iosSimulatorArm64]NamespaceSocket

NamespaceSocket

interface NamespaceSocket

Properties

connectionState

abstract val connectionState: StateFlow<ConnectionState>

errors

abstract val errors: Flow<SocketError>

abstract val id: StateFlow<String?>

Functions

abstract fun close()

emit

abstract fun emit(command: StreamCommand)

abstract fun emit(event: String, vararg payloads: Any?)

emitAwait

abstract suspend fun emitAwait(command: StreamCommand)

Same queue semantics as emitAwait for a StreamCommand.

abstract suspend fun emitAwait(event: String, vararg payloads: Any?)

Suspends until the event is accepted into the outbound queue (WorkQueue → engine write buffer). Completes when enqueue succeeds; does not await transport drain.

emitWithAck

abstract fun emitWithAck(event: String, vararg payloads: Any?): Flow<SocketEvent>

events

abstract fun events(name: String): Flow<SocketEvent>

Cold Flow of events named name. Backed by a hot buffer configured via SocketOptionsBuilder.eventBufferCapacity and SocketOptionsBuilder.eventBufferOverflow (default: capacity 64, EventBufferOverflow.DROP_OLDEST).

isConnected

abstract fun isConnected(): Boolean

isDisconnected

abstract fun isDisconnected(): Boolean

open

abstract fun open()

openAwait

abstract suspend fun openAwait()